-
Notifications
You must be signed in to change notification settings - Fork 2.2k
Cosmos CFP: fix for race condition issue #6205
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Conversation
… of the lease documents.
…een updated while we are trying to write the current state such as check-pointing the continuation token.
# Conflicts: # sdk/cosmos/changelog/README.md
kushagraThapar
left a comment
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Some suggestions around logger.error and logger.debug
otherwise looks good to me.
...src/main/java/com/azure/data/cosmos/internal/changefeed/implementation/AutoCheckpointer.java
Show resolved
Hide resolved
...src/main/java/com/azure/data/cosmos/internal/changefeed/implementation/AutoCheckpointer.java
Show resolved
Hide resolved
.../src/main/java/com/azure/data/cosmos/internal/changefeed/implementation/DefaultObserver.java
Show resolved
Hide resolved
|
/azp run java - cosmos - tests |
moderakh
left a comment
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
some minor questions and comments
...src/main/java/com/azure/data/cosmos/internal/changefeed/implementation/AutoCheckpointer.java
Outdated
Show resolved
Hide resolved
...src/main/java/com/azure/data/cosmos/internal/changefeed/implementation/AutoCheckpointer.java
Outdated
Show resolved
Hide resolved
...ain/java/com/azure/data/cosmos/internal/changefeed/implementation/LeaseStoreManagerImpl.java
Outdated
Show resolved
Hide resolved
...in/java/com/azure/data/cosmos/internal/changefeed/implementation/PartitionProcessorImpl.java
Outdated
Show resolved
Hide resolved
...in/java/com/azure/data/cosmos/internal/changefeed/implementation/PartitionProcessorImpl.java
Show resolved
Hide resolved
...in/java/com/azure/data/cosmos/internal/changefeed/implementation/PartitionProcessorImpl.java
Show resolved
Hide resolved
|
/azp run java - cosmos - tests |
ChangeFeedProcessor: fix a race condition issue where the lease document has been updated while we are trying to write the current state like when check-pointing the continuation token.